package com.yesep.learn.mqtt.protocol;

import io.netty.channel.Channel;
import io.netty.handler.codec.mqtt.MqttPublishMessage;

/**
 *   消息编号：3
* @Description: 发布消息
*/
public interface IPublish {
	/**
	   *  发布消息请求处理
	 * @param channel
	 * @param msg
	 */
	public void process(Channel channel, MqttPublishMessage msg);
}
